Home
last modified time | relevance | path

Searched refs:ixn (Results 126 – 150 of 420) sorted by relevance

12345678910>>...17

/dports/www/grafana8/grafana-8.3.6/vendor/github.com/hashicorp/consul/agent/structs/
H A Dintention_test.go231 ixn := TestIntention(t)
232 tc.Modify(ixn)
234 err := ixn.Validate()
317 for _, ixn := range input {
318 ixn.UpdatePrecedence()
366 ixn *Intention
448 tc.ixn.DefaultNamespaces(DefaultEnterpriseMeta())
449 tc.ixn.UpdatePrecedence()
452 got := tc.ixn.String()
H A Dintention.go300 func (ixn *Intention) CanRead(authz acl.Authorizer) bool {
310 if ixn.SourceName != "" {
311 ixn.FillAuthzContext(&authzContext, false)
312 if authz.IntentionRead(ixn.SourceName, &authzContext) == acl.Allow {
317 if ixn.DestinationName != "" {
318 ixn.FillAuthzContext(&authzContext, true)
319 if authz.IntentionRead(ixn.DestinationName, &authzContext) == acl.Allow {
327 func (ixn *Intention) CanWrite(authz acl.Authorizer) bool {
333 if ixn.DestinationName == "" {
337 ixn.FillAuthzContext(&authzContext, true)
[all …]
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/hashicorp/consul/agent/structs/
H A Dintention_test.go231 ixn := TestIntention(t)
232 tc.Modify(ixn)
234 err := ixn.Validate()
317 for _, ixn := range input {
318 ixn.UpdatePrecedence()
366 ixn *Intention
448 tc.ixn.DefaultNamespaces(DefaultEnterpriseMeta())
449 tc.ixn.UpdatePrecedence()
452 got := tc.ixn.String()
H A Dintention.go300 func (ixn *Intention) CanRead(authz acl.Authorizer) bool {
310 if ixn.SourceName != "" {
311 ixn.FillAuthzContext(&authzContext, false)
312 if authz.IntentionRead(ixn.SourceName, &authzContext) == acl.Allow {
317 if ixn.DestinationName != "" {
318 ixn.FillAuthzContext(&authzContext, true)
319 if authz.IntentionRead(ixn.DestinationName, &authzContext) == acl.Allow {
327 func (ixn *Intention) CanWrite(authz acl.Authorizer) bool {
333 if ixn.DestinationName == "" {
337 ixn.FillAuthzContext(&authzContext, true)
[all …]
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/github.com/hashicorp/consul/agent/consul/
H A Dintention_endpoint.go33 if _, ixn, err := state.IntentionGet(nil, id); err != nil {
35 } else if ixn != nil {
111 if ixn == nil {
118 if !ixn.CanWrite(authz) {
158 _, ixn, err := state.IntentionGet(nil, args.Intention.ID)
162 if ixn == nil {
169 if !ixn.CanWrite(authz) {
260 if ixn == nil {
265 reply.Intentions = structs.Intentions{ixn}
457 for _, ixn := range matches[0] {
[all …]
H A Dleader_connect_test.go841 ixn := structs.IntentionRequest{
861 ixn.Intention.ID = reply
888 ixn.Intention.ID = reply
889 ixn.Intention.SourceName = "*"
893 ixn.Intention.ID = reply
917 ixn.Intention.UpdatePrecedence()
963 ixn := structs.IntentionRequest{
982 ixn.Intention.ID = reply
1004 ixn.Intention.ID = reply
1005 ixn.Intention.SourceName = "*"
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/consul/agent/consul/
H A Dleader_connect_test.go841 ixn := structs.IntentionRequest{
861 ixn.Intention.ID = reply
888 ixn.Intention.ID = reply
889 ixn.Intention.SourceName = "*"
893 ixn.Intention.ID = reply
917 ixn.Intention.UpdatePrecedence()
963 ixn := structs.IntentionRequest{
982 ixn.Intention.ID = reply
1004 ixn.Intention.ID = reply
1005 ixn.Intention.SourceName = "*"
[all …]
/dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/hashicorp/consul/agent/structs/
H A Dintention_test.go150 ixn := TestIntention(t)
151 tc.Modify(ixn)
153 err := ixn.Validate()
236 for _, ixn := range input {
237 ixn.UpdatePrecedence()
/dports/www/fabio/fabio-1.5.14/vendor/github.com/hashicorp/consul/consul-1.4.2/agent/structs/
H A Dintention_test.go150 ixn := TestIntention(t)
151 tc.Modify(ixn)
153 err := ixn.Validate()
236 for _, ixn := range input {
237 ixn.UpdatePrecedence()
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/hashicorp/consul/agent/structs/
H A Dintention_test.go150 ixn := TestIntention(t)
151 tc.Modify(ixn)
153 err := ixn.Validate()
236 for _, ixn := range input {
237 ixn.UpdatePrecedence()
/dports/sysutils/consul/consul-1.10.3/agent/xds/
H A Drbac.go51 for _, ixn := range intentions {
52 rixn := intentionToIntermediateRBACForm(ixn, isHTTP)
192 Source: ixn.SourceServiceName(),
193 Precedence: ixn.Precedence,
195 if len(ixn.Permissions) > 0 {
198 rixn.Permissions = make([]*rbacPermission, 0, len(ixn.Permissions))
199 for _, perm := range ixn.Permissions {
211 rixn.Action = intentionActionFromString(ixn.Action)
470 for _, ixn := range intentions {
471 sn := ixn.SourceServiceName()
[all …]
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/hashicorp/consul/agent/xds/
H A Drbac.go51 for _, ixn := range intentions {
52 rixn := intentionToIntermediateRBACForm(ixn, isHTTP)
192 Source: ixn.SourceServiceName(),
193 Precedence: ixn.Precedence,
195 if len(ixn.Permissions) > 0 {
198 rixn.Permissions = make([]*rbacPermission, 0, len(ixn.Permissions))
199 for _, perm := range ixn.Permissions {
211 rixn.Action = intentionActionFromString(ixn.Action)
470 for _, ixn := range intentions {
471 sn := ixn.SourceServiceName()
[all …]
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/hashicorp/consul/agent/xds/
H A Drbac.go51 for _, ixn := range intentions {
52 rixn := intentionToIntermediateRBACForm(ixn, isHTTP)
192 Source: ixn.SourceServiceName(),
193 Precedence: ixn.Precedence,
195 if len(ixn.Permissions) > 0 {
198 rixn.Permissions = make([]*rbacPermission, 0, len(ixn.Permissions))
199 for _, perm := range ixn.Permissions {
211 rixn.Action = intentionActionFromString(ixn.Action)
470 for _, ixn := range intentions {
471 sn := ixn.SourceServiceName()
[all …]
/dports/sysutils/consul/consul-1.10.3/agent/structs/
H A Dintention.go300 func (ixn *Intention) CanRead(authz acl.Authorizer) bool {
310 if ixn.SourceName != "" {
311 ixn.FillAuthzContext(&authzContext, false)
312 if authz.IntentionRead(ixn.SourceName, &authzContext) == acl.Allow {
317 if ixn.DestinationName != "" {
318 ixn.FillAuthzContext(&authzContext, true)
319 if authz.IntentionRead(ixn.DestinationName, &authzContext) == acl.Allow {
327 func (ixn *Intention) CanWrite(authz acl.Authorizer) bool {
333 if ixn.DestinationName == "" {
337 ixn.FillAuthzContext(&authzContext, true)
[all …]
/dports/net/traefik/traefik-2.6.1/vendor/github.com/hashicorp/consul/agent/structs/
H A Dintention.go300 func (ixn *Intention) CanRead(authz acl.Authorizer) bool {
310 if ixn.SourceName != "" {
311 ixn.FillAuthzContext(&authzContext, false)
312 if authz.IntentionRead(ixn.SourceName, &authzContext) == acl.Allow {
317 if ixn.DestinationName != "" {
318 ixn.FillAuthzContext(&authzContext, true)
319 if authz.IntentionRead(ixn.DestinationName, &authzContext) == acl.Allow {
327 func (ixn *Intention) CanWrite(authz acl.Authorizer) bool {
333 if ixn.DestinationName == "" {
337 ixn.FillAuthzContext(&authzContext, true)
[all …]
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/github.com/hashicorp/consul/agent/structs/
H A Dintention_test.go230 ixn := TestIntention(t)
231 tc.Modify(ixn)
233 err := ixn.Validate()
316 for _, ixn := range input {
317 ixn.UpdatePrecedence()
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/consul/agent/structs/
H A Dintention_test.go231 ixn := TestIntention(t)
232 tc.Modify(ixn)
234 err := ixn.Validate()
317 for _, ixn := range input {
318 ixn.UpdatePrecedence()
/dports/www/fabio/fabio-1.5.14/vendor/github.com/hashicorp/consul/consul-1.4.2/agent/
H A Dconnect_auth.go98 for _, ixn := range reply.Matches[0] {
99 if auth, ok := uriService.Authorize(ixn); ok {
100 reason = fmt.Sprintf("Matched intention: %s", ixn.String())
/dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/github.com/prometheus/prometheus/vendor/github.com/hashicorp/consul/api/
H A Dconnect_intention.go267 func (c *Connect) IntentionCreate(ixn *Intention, q *WriteOptions) (string, *WriteMeta, error) {
270 r.obj = ixn
289 func (c *Connect) IntentionUpdate(ixn *Intention, q *WriteOptions) (*WriteMeta, error) {
290 r := c.c.newRequest("PUT", "/v1/connect/intentions/"+ixn.ID)
292 r.obj = ixn
/dports/misc/concourse/vault-bdd38fca2cff/vendor/github.com/hashicorp/consul/api/
H A Dconnect_intention.go267 func (c *Connect) IntentionCreate(ixn *Intention, q *WriteOptions) (string, *WriteMeta, error) {
270 r.obj = ixn
289 func (c *Connect) IntentionUpdate(ixn *Intention, q *WriteOptions) (*WriteMeta, error) {
290 r := c.c.newRequest("PUT", "/v1/connect/intentions/"+ixn.ID)
292 r.obj = ixn
/dports/misc/concourse/concourse-6.7.2/vendor/github.com/hashicorp/vault/vendor/github.com/hashicorp/consul/api/
H A Dconnect_intention.go267 func (c *Connect) IntentionCreate(ixn *Intention, q *WriteOptions) (string, *WriteMeta, error) {
270 r.obj = ixn
289 func (c *Connect) IntentionUpdate(ixn *Intention, q *WriteOptions) (*WriteMeta, error) {
290 r := c.c.newRequest("PUT", "/v1/connect/intentions/"+ixn.ID)
292 r.obj = ixn
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/github.com/hashicorp/vault/vendor/github.com/hashicorp/consul/api/
H A Dconnect_intention.go267 func (c *Connect) IntentionCreate(ixn *Intention, q *WriteOptions) (string, *WriteMeta, error) {
270 r.obj = ixn
289 func (c *Connect) IntentionUpdate(ixn *Intention, q *WriteOptions) (*WriteMeta, error) {
290 r := c.c.newRequest("PUT", "/v1/connect/intentions/"+ixn.ID)
292 r.obj = ixn
/dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/prometheus/prometheus/vendor/github.com/hashicorp/consul/api/
H A Dconnect_intention.go267 func (c *Connect) IntentionCreate(ixn *Intention, q *WriteOptions) (string, *WriteMeta, error) {
270 r.obj = ixn
289 func (c *Connect) IntentionUpdate(ixn *Intention, q *WriteOptions) (*WriteMeta, error) {
290 r := c.c.newRequest("PUT", "/v1/connect/intentions/"+ixn.ID)
292 r.obj = ixn
/dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/hashicorp/consul/api/
H A Dconnect_intention.go267 func (c *Connect) IntentionCreate(ixn *Intention, q *WriteOptions) (string, *WriteMeta, error) {
270 r.obj = ixn
289 func (c *Connect) IntentionUpdate(ixn *Intention, q *WriteOptions) (*WriteMeta, error) {
290 r := c.c.newRequest("PUT", "/v1/connect/intentions/"+ixn.ID)
292 r.obj = ixn
/dports/www/fabio/fabio-1.5.14/vendor/github.com/hashicorp/consul/api/
H A Dconnect_intention.go267 func (c *Connect) IntentionCreate(ixn *Intention, q *WriteOptions) (string, *WriteMeta, error) {
270 r.obj = ixn
289 func (c *Connect) IntentionUpdate(ixn *Intention, q *WriteOptions) (*WriteMeta, error) {
290 r := c.c.newRequest("PUT", "/v1/connect/intentions/"+ixn.ID)
292 r.obj = ixn

12345678910>>...17