transport

Documentation

Index

• Variables
• func DecodeHealthCheckRequest(ctx context.Context, r interface{}) (interface{}, error)
• func DecodeUpdateRequest(ctx context.Context, r interface{}) (interface{}, error)
• func DecodeViewRequest(ctx context.Context, r interface{}) (interface{}, error)
• func DecodeWatchRequest(ctx context.Context, r interface{}) (interface{}, error)
• func EncodeHealthCheckResponse(_ context.Context, r interface{}) (interface{}, error)
• func EncodeUpdateResponse(_ context.Context, r interface{}) (interface{}, error)
• func EncodeViewResponse(_ context.Context, r interface{}) (interface{}, error)
• func EncodeWatchResponse(_ context.Context, r interface{}) (interface{}, error)
• func NewGRPCHandlers(ctx context.Context, endpoints endpoint.BifrostEndpoints) *gRPCHandlers
• func NewHealthCheckHandler(ctx context.Context, endpoints endpoint.BifrostEndpoints) grpc_health_v1.HealthServer

Variables

var (
	ChunkSize = 1024

	ErrRequestInconsistent       = errors.New("the request is inconsistent")
	ErrRecvTimeout               = errors.New("receive timeout during data wrap")
	ErrUnknownRequest            = errors.New("unknown request error")
	ErrInvalidHealthCheckRequest = errors.New("request has only one: HealthCheckRequest")
	ErrUnknownResponse           = errors.New("unknown response error")

	ErrWatcherCloseTimeout = errors.New("close watcher timeout")
)

Functions

func DecodeHealthCheckRequest

func DecodeHealthCheckRequest(ctx context.Context, r interface{}) (interface{}, error)

func DecodeUpdateRequest

func DecodeUpdateRequest(ctx context.Context, r interface{}) (interface{}, error)

func DecodeViewRequest

func DecodeViewRequest(ctx context.Context, r interface{}) (interface{}, error)

func DecodeWatchRequest

func DecodeWatchRequest(ctx context.Context, r interface{}) (interface{}, error)

func EncodeHealthCheckResponse

func EncodeHealthCheckResponse(_ context.Context, r interface{}) (interface{}, error)

func EncodeUpdateResponse

func EncodeUpdateResponse(_ context.Context, r interface{}) (interface{}, error)

func EncodeViewResponse

func EncodeViewResponse(_ context.Context, r interface{}) (interface{}, error)

func EncodeWatchResponse

func EncodeWatchResponse(_ context.Context, r interface{}) (interface{}, error)

func NewGRPCHandlers

func NewGRPCHandlers(ctx context.Context, endpoints endpoint.BifrostEndpoints) *gRPCHandlers

func NewHealthCheckHandler

func NewHealthCheckHandler(ctx context.Context, endpoints endpoint.BifrostEndpoints) grpc_health_v1.HealthServer