controlpb

type ArgSpec struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Required    bool   `protobuf:"varint,3,opt,name=required,proto3" json:"required,omitempty"`
	// contains filtered or unexported fields
}

type ControlClient interface {
	ListInvocations(ctx context.Context, in *ListInvocationsRequest, opts ...grpc.CallOption) (*ListInvocationsResponse, error)
	Invoke(ctx context.Context, in *InvokeRequest, opts ...grpc.CallOption) (*InvokeResponse, error)
	// InvokeStream is the streaming twin of Invoke, for invocations that emit a
	// stream of results.
	InvokeStream(ctx context.Context, in *InvokeRequest, opts ...grpc.CallOption) (Control_InvokeStreamClient, error)
}

type ControlServer interface {
	ListInvocations(context.Context, *ListInvocationsRequest) (*ListInvocationsResponse, error)
	Invoke(context.Context, *InvokeRequest) (*InvokeResponse, error)
	// InvokeStream is the streaming twin of Invoke, for invocations that emit a
	// stream of results.
	InvokeStream(*InvokeRequest, Control_InvokeStreamServer) error
	// contains filtered or unexported methods
}

type Control_InvokeStreamClient interface {
	Recv() (*InvokeResponse, error)
	grpc.ClientStream
}

type Control_InvokeStreamServer interface {
	Send(*InvokeResponse) error
	grpc.ServerStream
}

type InvocationSpec struct {
	Name        string     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description string     `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Args        []*ArgSpec `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
	// kind is readonly|mutating|dangerous, used for audit and gating.
	Kind string `protobuf:"bytes,4,opt,name=kind,proto3" json:"kind,omitempty"`
	// streaming reports the invocation emits a stream of results (via
	// InvokeStream) rather than a single one (Invoke).
	Streaming bool `protobuf:"varint,5,opt,name=streaming,proto3" json:"streaming,omitempty"`
	// contains filtered or unexported fields
}

type InvokeRequest struct {

	// target is the node id "host:port/service" of a service instance.
	Target     string            `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	Invocation string            `protobuf:"bytes,2,opt,name=invocation,proto3" json:"invocation,omitempty"`
	Args       map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

type InvokeResponse struct {
	ResultJson string `protobuf:"bytes,1,opt,name=result_json,json=resultJson,proto3" json:"result_json,omitempty"`
	Error      string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type ListInvocationsRequest struct {

	// target is the node id "host:port/service" of a service instance.
	Target string `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

type ListInvocationsResponse struct {
	Invocations []*InvocationSpec `protobuf:"bytes,1,rep,name=invocations,proto3" json:"invocations,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedControlServer struct {
}

type UnsafeControlServer interface {
	// contains filtered or unexported methods
}