api

package
v0.146.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 19, 2024 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	FanoutService_Describe_FullMethodName             = "/api.FanoutService/Describe"
	FanoutService_ValidateRegistration_FullMethodName = "/api.FanoutService/ValidateRegistration"
	FanoutService_ValidateAttachment_FullMethodName   = "/api.FanoutService/ValidateAttachment"
	FanoutService_String_FullMethodName               = "/api.FanoutService/String"
	FanoutService_IsSubscribedTo_FullMethodName       = "/api.FanoutService/IsSubscribedTo"
	FanoutService_Register_FullMethodName             = "/api.FanoutService/Register"
	FanoutService_Attach_FullMethodName               = "/api.FanoutService/Attach"
	FanoutService_Execute_FullMethodName              = "/api.FanoutService/Execute"
)

Variables

View Source 
var FanoutService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.FanoutService",
	HandlerType: (*FanoutServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Describe",
			Handler:    _FanoutService_Describe_Handler,
		},
		{
			MethodName: "ValidateRegistration",
			Handler:    _FanoutService_ValidateRegistration_Handler,
		},
		{
			MethodName: "ValidateAttachment",
			Handler:    _FanoutService_ValidateAttachment_Handler,
		},
		{
			MethodName: "String",
			Handler:    _FanoutService_String_Handler,
		},
		{
			MethodName: "IsSubscribedTo",
			Handler:    _FanoutService_IsSubscribedTo_Handler,
		},
		{
			MethodName: "Register",
			Handler:    _FanoutService_Register_Handler,
		},
		{
			MethodName: "Attach",
			Handler:    _FanoutService_Attach_Handler,
		},
		{
			MethodName: "Execute",
			Handler:    _FanoutService_Execute_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "fanout.proto",
}

FanoutService_ServiceDesc is the grpc.ServiceDesc for FanoutService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_fanout_proto protoreflect.FileDescriptor

Functions

func AttachProtoToSDK 

func AttachProtoToSDK(in *AttachResponse) (*sdk.AttachmentResponse, error)

func DescribeProtoToSDK 

func DescribeProtoToSDK(pd *DescribeResponse) (*sdk.IntegrationInfo, error)

func MaterialProtoToSDK 

func MaterialProtoToSDK(in *ExecuteRequest_NormalizedMaterial) *sdk.ExecuteMaterial

func MetadataProtoToSDK 

func MetadataProtoToSDK(in *ExecuteRequest_Metadata) *sdk.ChainloopMetadata

func ProtoErrToErr 

func ProtoErrToErr(err error) error

func RegisterFanoutServiceServer 

func RegisterFanoutServiceServer(s grpc.ServiceRegistrar, srv FanoutServiceServer)

func RegistrationProtoToSDK 

func RegistrationProtoToSDK(in *RegisterResponse) (*sdk.RegistrationResponse, error)

Types

type AttachRequest 

type AttachRequest struct {
	Payload          []byte            `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	RegistrationInfo *RegisterResponse `protobuf:"bytes,2,opt,name=registration_info,json=registrationInfo,proto3" json:"registration_info,omitempty"`
	// contains filtered or unexported fields
}

func (*AttachRequest) Descriptor deprecated 

func (*AttachRequest) Descriptor() ([]byte, []int)

Deprecated: Use AttachRequest.ProtoReflect.Descriptor instead.

func (*AttachRequest) GetPayload 

func (x *AttachRequest) GetPayload() []byte

func (*AttachRequest) GetRegistrationInfo 

func (x *AttachRequest) GetRegistrationInfo() *RegisterResponse

func (*AttachRequest) ProtoMessage 

func (*AttachRequest) ProtoMessage()

func (*AttachRequest) ProtoReflect 

func (x *AttachRequest) ProtoReflect() protoreflect.Message

func (*AttachRequest) Reset 

func (x *AttachRequest) Reset()

func (*AttachRequest) String 

func (x *AttachRequest) String() string

type AttachResponse 

type AttachResponse struct {
	Configuration []byte `protobuf:"bytes,1,opt,name=configuration,proto3" json:"configuration,omitempty"`
	// contains filtered or unexported fields
}

func AttachSDKToProto 

func AttachSDKToProto(in *sdk.AttachmentResponse) (*AttachResponse, error)

func (*AttachResponse) Descriptor deprecated 

func (*AttachResponse) Descriptor() ([]byte, []int)

Deprecated: Use AttachResponse.ProtoReflect.Descriptor instead.

func (*AttachResponse) GetConfiguration 

func (x *AttachResponse) GetConfiguration() []byte

func (*AttachResponse) ProtoMessage 

func (*AttachResponse) ProtoMessage()

func (*AttachResponse) ProtoReflect 

func (x *AttachResponse) ProtoReflect() protoreflect.Message

func (*AttachResponse) Reset 

func (x *AttachResponse) Reset()

func (*AttachResponse) String 

func (x *AttachResponse) String() string

type DescribeRequest 

type DescribeRequest struct {
	// contains filtered or unexported fields
}

func (*DescribeRequest) Descriptor deprecated 

func (*DescribeRequest) Descriptor() ([]byte, []int)

Deprecated: Use DescribeRequest.ProtoReflect.Descriptor instead.

func (*DescribeRequest) ProtoMessage 

func (*DescribeRequest) ProtoMessage()

func (*DescribeRequest) ProtoReflect 

func (x *DescribeRequest) ProtoReflect() protoreflect.Message

func (*DescribeRequest) Reset 

func (x *DescribeRequest) Reset()

func (*DescribeRequest) String 

func (x *DescribeRequest) String() string

type DescribeResponse 

type DescribeResponse struct {
	Id                     string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Version                string   `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Description            string   `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	RegistrationJsonSchema []byte   `` /* 129-byte string literal not displayed */
	AttachmentJsonSchema   []byte   `protobuf:"bytes,5,opt,name=attachment_json_schema,json=attachmentJsonSchema,proto3" json:"attachment_json_schema,omitempty"`
	SubscribedMaterials    []string `protobuf:"bytes,6,rep,name=subscribed_materials,json=subscribedMaterials,proto3" json:"subscribed_materials,omitempty"`
	// contains filtered or unexported fields
}

func DescribeSDKToProto 

func DescribeSDKToProto(in *sdk.IntegrationInfo) (*DescribeResponse, error)

func (*DescribeResponse) Descriptor deprecated 

func (*DescribeResponse) Descriptor() ([]byte, []int)

Deprecated: Use DescribeResponse.ProtoReflect.Descriptor instead.

func (*DescribeResponse) GetAttachmentJsonSchema 

func (x *DescribeResponse) GetAttachmentJsonSchema() []byte

func (*DescribeResponse) GetDescription 

func (x *DescribeResponse) GetDescription() string

func (*DescribeResponse) GetId 

func (x *DescribeResponse) GetId() string

func (*DescribeResponse) GetRegistrationJsonSchema 

func (x *DescribeResponse) GetRegistrationJsonSchema() []byte

func (*DescribeResponse) GetSubscribedMaterials 

func (x *DescribeResponse) GetSubscribedMaterials() []string

func (*DescribeResponse) GetVersion 

func (x *DescribeResponse) GetVersion() string

func (*DescribeResponse) ProtoMessage 

func (*DescribeResponse) ProtoMessage()

func (*DescribeResponse) ProtoReflect 

func (x *DescribeResponse) ProtoReflect() protoreflect.Message

func (*DescribeResponse) Reset 

func (x *DescribeResponse) Reset()

func (*DescribeResponse) String 

func (x *DescribeResponse) String() string

type ExecuteRequest 

type ExecuteRequest struct {

	// Previous outputs
	RegistrationInfo *RegisterResponse `protobuf:"bytes,1,opt,name=registration_info,json=registrationInfo,proto3" json:"registration_info,omitempty"`
	AttachmentInfo   *AttachResponse   `protobuf:"bytes,2,opt,name=attachment_info,json=attachmentInfo,proto3" json:"attachment_info,omitempty"`
	// Inputs
	Envelope  []byte                               `protobuf:"bytes,3,opt,name=envelope,proto3" json:"envelope,omitempty"`
	Materials []*ExecuteRequest_NormalizedMaterial `protobuf:"bytes,4,rep,name=materials,proto3" json:"materials,omitempty"`
	// Chainloop metadata
	Metadata *ExecuteRequest_Metadata `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteRequest) Descriptor deprecated 

func (*ExecuteRequest) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteRequest.ProtoReflect.Descriptor instead.

func (*ExecuteRequest) GetAttachmentInfo 

func (x *ExecuteRequest) GetAttachmentInfo() *AttachResponse

func (*ExecuteRequest) GetEnvelope 

func (x *ExecuteRequest) GetEnvelope() []byte

func (*ExecuteRequest) GetMaterials 

func (x *ExecuteRequest) GetMaterials() []*ExecuteRequest_NormalizedMaterial

func (*ExecuteRequest) GetMetadata 

func (x *ExecuteRequest) GetMetadata() *ExecuteRequest_Metadata

func (*ExecuteRequest) GetRegistrationInfo 

func (x *ExecuteRequest) GetRegistrationInfo() *RegisterResponse

func (*ExecuteRequest) ProtoMessage 

func (*ExecuteRequest) ProtoMessage()

func (*ExecuteRequest) ProtoReflect 

func (x *ExecuteRequest) ProtoReflect() protoreflect.Message

func (*ExecuteRequest) Reset 

func (x *ExecuteRequest) Reset()

func (*ExecuteRequest) String 

func (x *ExecuteRequest) String() string

type ExecuteRequest_Metadata 

type ExecuteRequest_Metadata struct {
	Workflow    *ExecuteRequest_Metadata_Workflow    `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"`
	WorkflowRun *ExecuteRequest_Metadata_WorkflowRun `protobuf:"bytes,2,opt,name=workflow_run,json=workflowRun,proto3" json:"workflow_run,omitempty"`
	// contains filtered or unexported fields
}

func MetadataSDKToProto 

func MetadataSDKToProto(in *sdk.ChainloopMetadata) *ExecuteRequest_Metadata

func (*ExecuteRequest_Metadata) Descriptor deprecated 

func (*ExecuteRequest_Metadata) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteRequest_Metadata.ProtoReflect.Descriptor instead.

func (*ExecuteRequest_Metadata) GetWorkflow added in v0.14.0 

func (x *ExecuteRequest_Metadata) GetWorkflow() *ExecuteRequest_Metadata_Workflow

func (*ExecuteRequest_Metadata) GetWorkflowRun added in v0.14.0 

func (x *ExecuteRequest_Metadata) GetWorkflowRun() *ExecuteRequest_Metadata_WorkflowRun

func (*ExecuteRequest_Metadata) ProtoMessage 

func (*ExecuteRequest_Metadata) ProtoMessage()

func (*ExecuteRequest_Metadata) ProtoReflect 

func (x *ExecuteRequest_Metadata) ProtoReflect() protoreflect.Message

func (*ExecuteRequest_Metadata) Reset 

func (x *ExecuteRequest_Metadata) Reset()

func (*ExecuteRequest_Metadata) String 

func (x *ExecuteRequest_Metadata) String() string

type ExecuteRequest_Metadata_Workflow added in v0.14.0 

type ExecuteRequest_Metadata_Workflow struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name    string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Team    string `protobuf:"bytes,3,opt,name=team,proto3" json:"team,omitempty"`
	Project string `protobuf:"bytes,4,opt,name=project,proto3" json:"project,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteRequest_Metadata_Workflow) Descriptor deprecated added in v0.14.0 

func (*ExecuteRequest_Metadata_Workflow) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteRequest_Metadata_Workflow.ProtoReflect.Descriptor instead.

func (*ExecuteRequest_Metadata_Workflow) GetId added in v0.14.0 

func (x *ExecuteRequest_Metadata_Workflow) GetId() string

func (*ExecuteRequest_Metadata_Workflow) GetName added in v0.14.0 

func (x *ExecuteRequest_Metadata_Workflow) GetName() string

func (*ExecuteRequest_Metadata_Workflow) GetProject added in v0.14.0 

func (x *ExecuteRequest_Metadata_Workflow) GetProject() string

func (*ExecuteRequest_Metadata_Workflow) GetTeam added in v0.14.0 

func (x *ExecuteRequest_Metadata_Workflow) GetTeam() string

func (*ExecuteRequest_Metadata_Workflow) ProtoMessage added in v0.14.0 

func (*ExecuteRequest_Metadata_Workflow) ProtoMessage()

func (*ExecuteRequest_Metadata_Workflow) ProtoReflect added in v0.14.0 

func (x *ExecuteRequest_Metadata_Workflow) ProtoReflect() protoreflect.Message

func (*ExecuteRequest_Metadata_Workflow) Reset added in v0.14.0 

func (x *ExecuteRequest_Metadata_Workflow) Reset()

func (*ExecuteRequest_Metadata_Workflow) String added in v0.14.0 

func (x *ExecuteRequest_Metadata_Workflow) String() string

type ExecuteRequest_Metadata_WorkflowRun added in v0.14.0 

type ExecuteRequest_Metadata_WorkflowRun struct {
	Id                string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State             string                 `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	RunnerType        string                 `protobuf:"bytes,3,opt,name=runner_type,json=runnerType,proto3" json:"runner_type,omitempty"`
	RunUrl            string                 `protobuf:"bytes,4,opt,name=run_url,json=runUrl,proto3" json:"run_url,omitempty"`
	StartedAt         *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	FinishedAt        *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	AttestationDigest string                 `protobuf:"bytes,7,opt,name=attestation_digest,json=attestationDigest,proto3" json:"attestation_digest,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteRequest_Metadata_WorkflowRun) Descriptor deprecated added in v0.14.0 

func (*ExecuteRequest_Metadata_WorkflowRun) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteRequest_Metadata_WorkflowRun.ProtoReflect.Descriptor instead.

func (*ExecuteRequest_Metadata_WorkflowRun) GetAttestationDigest added in v0.17.0 

func (x *ExecuteRequest_Metadata_WorkflowRun) GetAttestationDigest() string

func (*ExecuteRequest_Metadata_WorkflowRun) GetFinishedAt added in v0.14.0 

func (x *ExecuteRequest_Metadata_WorkflowRun) GetFinishedAt() *timestamppb.Timestamp

func (*ExecuteRequest_Metadata_WorkflowRun) GetId added in v0.14.0 

func (x *ExecuteRequest_Metadata_WorkflowRun) GetId() string

func (*ExecuteRequest_Metadata_WorkflowRun) GetRunUrl added in v0.14.0 

func (x *ExecuteRequest_Metadata_WorkflowRun) GetRunUrl() string

func (*ExecuteRequest_Metadata_WorkflowRun) GetRunnerType added in v0.14.0 

func (x *ExecuteRequest_Metadata_WorkflowRun) GetRunnerType() string

func (*ExecuteRequest_Metadata_WorkflowRun) GetStartedAt added in v0.14.0 

func (x *ExecuteRequest_Metadata_WorkflowRun) GetStartedAt() *timestamppb.Timestamp

func (*ExecuteRequest_Metadata_WorkflowRun) GetState added in v0.14.0 

func (x *ExecuteRequest_Metadata_WorkflowRun) GetState() string

func (*ExecuteRequest_Metadata_WorkflowRun) ProtoMessage added in v0.14.0 

func (*ExecuteRequest_Metadata_WorkflowRun) ProtoMessage()

func (*ExecuteRequest_Metadata_WorkflowRun) ProtoReflect added in v0.14.0 

func (x *ExecuteRequest_Metadata_WorkflowRun) ProtoReflect() protoreflect.Message

func (*ExecuteRequest_Metadata_WorkflowRun) Reset added in v0.14.0 

func (x *ExecuteRequest_Metadata_WorkflowRun) Reset()

func (*ExecuteRequest_Metadata_WorkflowRun) String added in v0.14.0 

func (x *ExecuteRequest_Metadata_WorkflowRun) String() string

type ExecuteRequest_NormalizedMaterial 

type ExecuteRequest_NormalizedMaterial struct {
	Content       []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	Name          string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Type          string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Value         string `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	Hash          string `protobuf:"bytes,5,opt,name=hash,proto3" json:"hash,omitempty"`
	UploadedToCas bool   `protobuf:"varint,6,opt,name=uploaded_to_cas,json=uploadedToCas,proto3" json:"uploaded_to_cas,omitempty"`
	FileName      string `protobuf:"bytes,7,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	// contains filtered or unexported fields
}

func MaterialSDKToProto 

func MaterialSDKToProto(in *sdk.ExecuteMaterial) *ExecuteRequest_NormalizedMaterial

func (*ExecuteRequest_NormalizedMaterial) Descriptor deprecated 

func (*ExecuteRequest_NormalizedMaterial) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteRequest_NormalizedMaterial.ProtoReflect.Descriptor instead.

func (*ExecuteRequest_NormalizedMaterial) GetContent 

func (x *ExecuteRequest_NormalizedMaterial) GetContent() []byte

func (*ExecuteRequest_NormalizedMaterial) GetFileName added in v0.14.0 

func (x *ExecuteRequest_NormalizedMaterial) GetFileName() string

func (*ExecuteRequest_NormalizedMaterial) GetHash 

func (x *ExecuteRequest_NormalizedMaterial) GetHash() string

func (*ExecuteRequest_NormalizedMaterial) GetName 

func (x *ExecuteRequest_NormalizedMaterial) GetName() string

func (*ExecuteRequest_NormalizedMaterial) GetType 

func (x *ExecuteRequest_NormalizedMaterial) GetType() string

func (*ExecuteRequest_NormalizedMaterial) GetUploadedToCas 

func (x *ExecuteRequest_NormalizedMaterial) GetUploadedToCas() bool

func (*ExecuteRequest_NormalizedMaterial) GetValue 

func (x *ExecuteRequest_NormalizedMaterial) GetValue() string

func (*ExecuteRequest_NormalizedMaterial) ProtoMessage 

func (*ExecuteRequest_NormalizedMaterial) ProtoMessage()

func (*ExecuteRequest_NormalizedMaterial) ProtoReflect 

func (x *ExecuteRequest_NormalizedMaterial) ProtoReflect() protoreflect.Message

func (*ExecuteRequest_NormalizedMaterial) Reset 

func (x *ExecuteRequest_NormalizedMaterial) Reset()

func (*ExecuteRequest_NormalizedMaterial) String 

func (x *ExecuteRequest_NormalizedMaterial) String() string

type ExecuteResponse 

type ExecuteResponse struct {
	// contains filtered or unexported fields
}

func (*ExecuteResponse) Descriptor deprecated 

func (*ExecuteResponse) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteResponse.ProtoReflect.Descriptor instead.

func (*ExecuteResponse) ProtoMessage 

func (*ExecuteResponse) ProtoMessage()

func (*ExecuteResponse) ProtoReflect 

func (x *ExecuteResponse) ProtoReflect() protoreflect.Message

func (*ExecuteResponse) Reset 

func (x *ExecuteResponse) Reset()

func (*ExecuteResponse) String 

func (x *ExecuteResponse) String() string

type FanoutServiceClient 

type FanoutServiceClient interface {
	// Core / Shared
	Describe(ctx context.Context, in *DescribeRequest, opts ...grpc.CallOption) (*DescribeResponse, error)
	ValidateRegistration(ctx context.Context, in *ValidateRegistrationRequest, opts ...grpc.CallOption) (*ValidateRegistrationResponse, error)
	ValidateAttachment(ctx context.Context, in *ValidateAttachmentRequest, opts ...grpc.CallOption) (*ValidateAttachmentResponse, error)
	String(ctx context.Context, in *StringRequest, opts ...grpc.CallOption) (*StringResponse, error)
	IsSubscribedTo(ctx context.Context, in *IsSubscribedToRequest, opts ...grpc.CallOption) (*IsSubscribedToResponse, error)
	// per-plugin
	Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterResponse, error)
	Attach(ctx context.Context, in *AttachRequest, opts ...grpc.CallOption) (*AttachResponse, error)
	Execute(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*ExecuteResponse, error)
}

FanoutServiceClient is the client API for FanoutService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewFanoutServiceClient 

func NewFanoutServiceClient(cc grpc.ClientConnInterface) FanoutServiceClient

type FanoutServiceServer 

type FanoutServiceServer interface {
	// Core / Shared
	Describe(context.Context, *DescribeRequest) (*DescribeResponse, error)
	ValidateRegistration(context.Context, *ValidateRegistrationRequest) (*ValidateRegistrationResponse, error)
	ValidateAttachment(context.Context, *ValidateAttachmentRequest) (*ValidateAttachmentResponse, error)
	String(context.Context, *StringRequest) (*StringResponse, error)
	IsSubscribedTo(context.Context, *IsSubscribedToRequest) (*IsSubscribedToResponse, error)
	// per-plugin
	Register(context.Context, *RegisterRequest) (*RegisterResponse, error)
	Attach(context.Context, *AttachRequest) (*AttachResponse, error)
	Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error)
	// contains filtered or unexported methods
}

FanoutServiceServer is the server API for FanoutService service. All implementations must embed UnimplementedFanoutServiceServer for forward compatibility

type IsSubscribedToRequest 

type IsSubscribedToRequest struct {
	MaterialType string `protobuf:"bytes,1,opt,name=material_type,json=materialType,proto3" json:"material_type,omitempty"`
	// contains filtered or unexported fields
}

func (*IsSubscribedToRequest) Descriptor deprecated 

func (*IsSubscribedToRequest) Descriptor() ([]byte, []int)

Deprecated: Use IsSubscribedToRequest.ProtoReflect.Descriptor instead.

func (*IsSubscribedToRequest) GetMaterialType 

func (x *IsSubscribedToRequest) GetMaterialType() string

func (*IsSubscribedToRequest) ProtoMessage 

func (*IsSubscribedToRequest) ProtoMessage()

func (*IsSubscribedToRequest) ProtoReflect 

func (x *IsSubscribedToRequest) ProtoReflect() protoreflect.Message

func (*IsSubscribedToRequest) Reset 

func (x *IsSubscribedToRequest) Reset()

func (*IsSubscribedToRequest) String 

func (x *IsSubscribedToRequest) String() string

type IsSubscribedToResponse 

type IsSubscribedToResponse struct {
	Subscribed bool `protobuf:"varint,1,opt,name=subscribed,proto3" json:"subscribed,omitempty"`
	// contains filtered or unexported fields
}

func (*IsSubscribedToResponse) Descriptor deprecated 

func (*IsSubscribedToResponse) Descriptor() ([]byte, []int)

Deprecated: Use IsSubscribedToResponse.ProtoReflect.Descriptor instead.

func (*IsSubscribedToResponse) GetSubscribed 

func (x *IsSubscribedToResponse) GetSubscribed() bool

func (*IsSubscribedToResponse) ProtoMessage 

func (*IsSubscribedToResponse) ProtoMessage()

func (*IsSubscribedToResponse) ProtoReflect 

func (x *IsSubscribedToResponse) ProtoReflect() protoreflect.Message

func (*IsSubscribedToResponse) Reset 

func (x *IsSubscribedToResponse) Reset()

func (*IsSubscribedToResponse) String 

func (x *IsSubscribedToResponse) String() string

type RegisterRequest 

type RegisterRequest struct {
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterRequest) Descriptor deprecated 

func (*RegisterRequest) Descriptor() ([]byte, []int)

Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.

func (*RegisterRequest) GetPayload 

func (x *RegisterRequest) GetPayload() []byte

func (*RegisterRequest) ProtoMessage 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) ProtoReflect 

func (x *RegisterRequest) ProtoReflect() protoreflect.Message

func (*RegisterRequest) Reset 

func (x *RegisterRequest) Reset()

func (*RegisterRequest) String 

func (x *RegisterRequest) String() string

type RegisterResponse 

type RegisterResponse struct {
	Configuration []byte                        `protobuf:"bytes,1,opt,name=configuration,proto3" json:"configuration,omitempty"`
	Credentials   *RegisterResponse_Credentials `protobuf:"bytes,2,opt,name=credentials,proto3" json:"credentials,omitempty"`
	// contains filtered or unexported fields
}

func RegistrationSDKToProto 

func RegistrationSDKToProto(in *sdk.RegistrationResponse) (*RegisterResponse, error)

func (*RegisterResponse) Descriptor deprecated 

func (*RegisterResponse) Descriptor() ([]byte, []int)

Deprecated: Use RegisterResponse.ProtoReflect.Descriptor instead.

func (*RegisterResponse) GetConfiguration 

func (x *RegisterResponse) GetConfiguration() []byte

func (*RegisterResponse) GetCredentials 

func (x *RegisterResponse) GetCredentials() *RegisterResponse_Credentials

func (*RegisterResponse) ProtoMessage 

func (*RegisterResponse) ProtoMessage()

func (*RegisterResponse) ProtoReflect 

func (x *RegisterResponse) ProtoReflect() protoreflect.Message

func (*RegisterResponse) Reset 

func (x *RegisterResponse) Reset()

func (*RegisterResponse) String 

func (x *RegisterResponse) String() string

type RegisterResponse_Credentials 

type RegisterResponse_Credentials struct {
	Url      string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterResponse_Credentials) Descriptor deprecated 

func (*RegisterResponse_Credentials) Descriptor() ([]byte, []int)

Deprecated: Use RegisterResponse_Credentials.ProtoReflect.Descriptor instead.

func (*RegisterResponse_Credentials) GetPassword 

func (x *RegisterResponse_Credentials) GetPassword() string

func (*RegisterResponse_Credentials) GetUrl 

func (x *RegisterResponse_Credentials) GetUrl() string

func (*RegisterResponse_Credentials) GetUsername 

func (x *RegisterResponse_Credentials) GetUsername() string

func (*RegisterResponse_Credentials) ProtoMessage 

func (*RegisterResponse_Credentials) ProtoMessage()

func (*RegisterResponse_Credentials) ProtoReflect 

func (x *RegisterResponse_Credentials) ProtoReflect() protoreflect.Message

func (*RegisterResponse_Credentials) Reset 

func (x *RegisterResponse_Credentials) Reset()

func (*RegisterResponse_Credentials) String 

func (x *RegisterResponse_Credentials) String() string

type StringRequest 

type StringRequest struct {
	// contains filtered or unexported fields
}

func (*StringRequest) Descriptor deprecated 

func (*StringRequest) Descriptor() ([]byte, []int)

Deprecated: Use StringRequest.ProtoReflect.Descriptor instead.

func (*StringRequest) ProtoMessage 

func (*StringRequest) ProtoMessage()

func (*StringRequest) ProtoReflect 

func (x *StringRequest) ProtoReflect() protoreflect.Message

func (*StringRequest) Reset 

func (x *StringRequest) Reset()

func (*StringRequest) String 

func (x *StringRequest) String() string

type StringResponse 

type StringResponse struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*StringResponse) Descriptor deprecated 

func (*StringResponse) Descriptor() ([]byte, []int)

Deprecated: Use StringResponse.ProtoReflect.Descriptor instead.

func (*StringResponse) GetValue 

func (x *StringResponse) GetValue() string

func (*StringResponse) ProtoMessage 

func (*StringResponse) ProtoMessage()

func (*StringResponse) ProtoReflect 

func (x *StringResponse) ProtoReflect() protoreflect.Message

func (*StringResponse) Reset 

func (x *StringResponse) Reset()

func (*StringResponse) String 

func (x *StringResponse) String() string

type UnimplementedFanoutServiceServer 

type UnimplementedFanoutServiceServer struct {
}

UnimplementedFanoutServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFanoutServiceServer) Attach 

func (UnimplementedFanoutServiceServer) Attach(context.Context, *AttachRequest) (*AttachResponse, error)

func (UnimplementedFanoutServiceServer) Describe 

func (UnimplementedFanoutServiceServer) Describe(context.Context, *DescribeRequest) (*DescribeResponse, error)

func (UnimplementedFanoutServiceServer) Execute 

func (UnimplementedFanoutServiceServer) Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error)

func (UnimplementedFanoutServiceServer) IsSubscribedTo 

func (UnimplementedFanoutServiceServer) IsSubscribedTo(context.Context, *IsSubscribedToRequest) (*IsSubscribedToResponse, error)

func (UnimplementedFanoutServiceServer) Register 

func (UnimplementedFanoutServiceServer) Register(context.Context, *RegisterRequest) (*RegisterResponse, error)

func (UnimplementedFanoutServiceServer) String 

func (UnimplementedFanoutServiceServer) String(context.Context, *StringRequest) (*StringResponse, error)

func (UnimplementedFanoutServiceServer) ValidateAttachment 

func (UnimplementedFanoutServiceServer) ValidateAttachment(context.Context, *ValidateAttachmentRequest) (*ValidateAttachmentResponse, error)

func (UnimplementedFanoutServiceServer) ValidateRegistration 

func (UnimplementedFanoutServiceServer) ValidateRegistration(context.Context, *ValidateRegistrationRequest) (*ValidateRegistrationResponse, error)

type UnsafeFanoutServiceServer 

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

UnsafeFanoutServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FanoutServiceServer will result in compilation errors.

type ValidateAttachmentRequest 

type ValidateAttachmentRequest struct {
	JsonPayload []byte `protobuf:"bytes,1,opt,name=json_payload,json=jsonPayload,proto3" json:"json_payload,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateAttachmentRequest) Descriptor deprecated 

func (*ValidateAttachmentRequest) Descriptor() ([]byte, []int)

Deprecated: Use ValidateAttachmentRequest.ProtoReflect.Descriptor instead.

func (*ValidateAttachmentRequest) GetJsonPayload 

func (x *ValidateAttachmentRequest) GetJsonPayload() []byte

func (*ValidateAttachmentRequest) ProtoMessage 

func (*ValidateAttachmentRequest) ProtoMessage()

func (*ValidateAttachmentRequest) ProtoReflect 

func (x *ValidateAttachmentRequest) ProtoReflect() protoreflect.Message

func (*ValidateAttachmentRequest) Reset 

func (x *ValidateAttachmentRequest) Reset()

func (*ValidateAttachmentRequest) String 

func (x *ValidateAttachmentRequest) String() string

type ValidateAttachmentResponse 

type ValidateAttachmentResponse struct {
	Valid bool   `protobuf:"varint,1,opt,name=valid,proto3" json:"valid,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateAttachmentResponse) Descriptor deprecated 

func (*ValidateAttachmentResponse) Descriptor() ([]byte, []int)

Deprecated: Use ValidateAttachmentResponse.ProtoReflect.Descriptor instead.

func (*ValidateAttachmentResponse) GetError 

func (x *ValidateAttachmentResponse) GetError() string

func (*ValidateAttachmentResponse) GetValid 

func (x *ValidateAttachmentResponse) GetValid() bool

func (*ValidateAttachmentResponse) ProtoMessage 

func (*ValidateAttachmentResponse) ProtoMessage()

func (*ValidateAttachmentResponse) ProtoReflect 

func (x *ValidateAttachmentResponse) ProtoReflect() protoreflect.Message

func (*ValidateAttachmentResponse) Reset 

func (x *ValidateAttachmentResponse) Reset()

func (*ValidateAttachmentResponse) String 

func (x *ValidateAttachmentResponse) String() string

type ValidateRegistrationRequest 

type ValidateRegistrationRequest struct {
	JsonPayload []byte `protobuf:"bytes,1,opt,name=json_payload,json=jsonPayload,proto3" json:"json_payload,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateRegistrationRequest) Descriptor deprecated 

func (*ValidateRegistrationRequest) Descriptor() ([]byte, []int)

Deprecated: Use ValidateRegistrationRequest.ProtoReflect.Descriptor instead.

func (*ValidateRegistrationRequest) GetJsonPayload 

func (x *ValidateRegistrationRequest) GetJsonPayload() []byte

func (*ValidateRegistrationRequest) ProtoMessage 

func (*ValidateRegistrationRequest) ProtoMessage()

func (*ValidateRegistrationRequest) ProtoReflect 

func (x *ValidateRegistrationRequest) ProtoReflect() protoreflect.Message

func (*ValidateRegistrationRequest) Reset 

func (x *ValidateRegistrationRequest) Reset()

func (*ValidateRegistrationRequest) String 

func (x *ValidateRegistrationRequest) String() string

type ValidateRegistrationResponse 

type ValidateRegistrationResponse struct {
	Valid bool   `protobuf:"varint,1,opt,name=valid,proto3" json:"valid,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateRegistrationResponse) Descriptor deprecated 

func (*ValidateRegistrationResponse) Descriptor() ([]byte, []int)

Deprecated: Use ValidateRegistrationResponse.ProtoReflect.Descriptor instead.

func (*ValidateRegistrationResponse) GetError 

func (x *ValidateRegistrationResponse) GetError() string

func (*ValidateRegistrationResponse) GetValid 

func (x *ValidateRegistrationResponse) GetValid() bool

func (*ValidateRegistrationResponse) ProtoMessage 

func (*ValidateRegistrationResponse) ProtoMessage()

func (*ValidateRegistrationResponse) ProtoReflect 

func (x *ValidateRegistrationResponse) ProtoReflect() protoreflect.Message

func (*ValidateRegistrationResponse) Reset 

func (x *ValidateRegistrationResponse) Reset()

func (*ValidateRegistrationResponse) String 

func (x *ValidateRegistrationResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.