proxy

type FailureVisitorInterceptorOptions struct {
	// Visit options for outbound messages
	Outbound *VisitFailuresOptions
	// Visit options for inbound messages
	Inbound *VisitFailuresOptions
}

type PayloadVisitorInterceptorOptions struct {
	// Visit options for outbound messages
	Outbound *VisitPayloadsOptions
	// Visit options for inbound messages
	Inbound *VisitPayloadsOptions
}

type VisitFailuresContext struct {
	context.Context
	// The parent message for this failure.
	Parent proto.Message
}

type VisitFailuresOptions struct {
	// Context is the same for every call of a visit, callers should not store it.
	// Visitor is free to mutate the passed failure struct.
	Visitor func(*VisitFailuresContext, *failure.Failure) error
	// Will be called for each Any encountered. If not set, the default is to recurse into the Any
	// object, unmarshal it, visit, and re-marshal it always (even if there are no changes).
	WellKnownAnyVisitor func(*VisitFailuresContext, *anypb.Any) error
}

type VisitPayloadsContext struct {
	context.Context
	// The parent message for this payload.
	Parent proto.Message
	// If true, a single payload is given and a single payload must be returned.
	SinglePayloadRequired bool
}

type VisitPayloadsOptions struct {
	// Context is the same for every call of a visit, callers should not store it. This must never
	// return an empty set of payloads.
	Visitor func(*VisitPayloadsContext, []*common.Payload) ([]*common.Payload, error)
	// Don't visit search attribute payloads.
	SkipSearchAttributes bool
	// Will be called for each Any encountered. If not set, the default is to recurse into the Any
	// object, unmarshal it, visit, and re-marshal it always (even if there are no changes).
	WellKnownAnyVisitor func(*VisitPayloadsContext, *anypb.Any) error
}

type WorkflowServiceProxyOptions struct {
	Client                  workflowservice.WorkflowServiceClient
	DisableHeaderForwarding bool
}