Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

dispatch

package

Go to main page

Versions in this module

v0

v0.0.3

Oct 22, 2024

Changes in this version

+ type LookupResources2 interface

+ DispatchLookupResources2 func(req *v1.DispatchLookupResources2Request, stream LookupResources2Stream) error

+ type LookupResources2Stream = Stream[*v1.DispatchLookupResources2Response]

type MaxDepthExceededError

+ func (err MaxDepthExceededError) GRPCStatus() *status.Status

v0.0.2

Jun 3, 2024

Changes in this version

+ func AddResponseMetadata(existing *v1.ResponseMeta, incoming *v1.ResponseMeta)

+ func CheckDepth(ctx context.Context, req DispatchableRequest) error

+ func NewMaxDepthExceededError(req DispatchableRequest) error

+ type Check interface

+ DispatchCheck func(ctx context.Context, req *v1.DispatchCheckRequest) (*v1.DispatchCheckResponse, error)

+ type CollectingDispatchStream struct

+ func NewCollectingDispatchStream[T any](ctx context.Context) *CollectingDispatchStream[T]

+ func (s *CollectingDispatchStream[T]) Context() context.Context

+ func (s *CollectingDispatchStream[T]) Publish(result T) error

+ func (s *CollectingDispatchStream[T]) Results() []T

+ type CountingDispatchStream struct

+ Stream Stream[T]

+ func NewCountingDispatchStream[T any](wrapped Stream[T]) *CountingDispatchStream[T]

+ func (s *CountingDispatchStream[T]) Context() context.Context

+ func (s *CountingDispatchStream[T]) Publish(result T) error

+ func (s *CountingDispatchStream[T]) PublishedCount() uint64

+ type DispatchableRequest interface

+ GetMetadata func() *v1.ResolverMeta

+ type Dispatcher interface

+ Close func() error

+ ReadyState func() ReadyState

+ type Expand interface

+ DispatchExpand func(ctx context.Context, req *v1.DispatchExpandRequest) (*v1.DispatchExpandResponse, error)

+ type HandlingDispatchStream struct

+ func (s *HandlingDispatchStream[T]) Context() context.Context

+ func (s *HandlingDispatchStream[T]) Publish(result T) error

+ type LookupResources interface

+ DispatchLookupResources func(req *v1.DispatchLookupResourcesRequest, stream LookupResourcesStream) error

+ type LookupResourcesStream = Stream[*v1.DispatchLookupResourcesResponse]

+ type LookupSubjects interface

+ DispatchLookupSubjects func(req *v1.DispatchLookupSubjectsRequest, stream LookupSubjectsStream) error

+ type LookupSubjectsStream = Stream[*v1.DispatchLookupSubjectsResponse]

+ type MaxDepthExceededError struct

+ Request DispatchableRequest

+ type ReachableResources interface

+ DispatchReachableResources func(req *v1.DispatchReachableResourcesRequest, stream ReachableResourcesStream) error

+ type ReachableResourcesStream = Stream[*v1.DispatchReachableResourcesResponse]

+ type ReadyState struct

+ IsReady bool

+ Message string

+ type Stream interface

+ Context func() context.Context

+ Publish func(T) error

+ func NewHandlingDispatchStream[T any](ctx context.Context, processor func(result T) error) Stream[T]

+ func StreamWithContext[T any](context context.Context, stream Stream[T]) Stream[T]

+ func WrapGRPCStream[R any, S grpcStream[R]](grpcStream S) Stream[R]

+ type WrappedDispatchStream struct

+ Ctx context.Context

+ Processor func(result T) (T, bool, error)

+ Stream Stream[T]

+ func (s *WrappedDispatchStream[T]) Context() context.Context

+ func (s *WrappedDispatchStream[T]) Publish(result T) error