channel_schemasv1

package
v0.0.0-...-77c09b6 Latest Latest
Warning

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

 Go to latest Published: May 27, 2024 License: MIT Imports: 21 Imported by: 0

Documentation

Overview

Package channel_schemasv1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var ChannelSchemaService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "sift.channel_schemas.v1.ChannelSchemaService",
	HandlerType: (*ChannelSchemaServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateChannelSchema",
			Handler:    _ChannelSchemaService_CreateChannelSchema_Handler,
		},
		{
			MethodName: "BatchCreateChannelSchemas",
			Handler:    _ChannelSchemaService_BatchCreateChannelSchemas_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "sift/channel_schemas/v1/channel_schemas.proto",
}

ChannelSchemaService_ServiceDesc is the grpc.ServiceDesc for ChannelSchemaService 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_sift_channel_schemas_v1_channel_schemas_proto protoreflect.FileDescriptor

Functions

func RegisterChannelSchemaServiceHandler 

func RegisterChannelSchemaServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterChannelSchemaServiceHandler registers the http handlers for service ChannelSchemaService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterChannelSchemaServiceHandlerClient 

func RegisterChannelSchemaServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ChannelSchemaServiceClient) error

RegisterChannelSchemaServiceHandlerClient registers the http handlers for service ChannelSchemaService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ChannelSchemaServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ChannelSchemaServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ChannelSchemaServiceClient" to call the correct interceptors.

func RegisterChannelSchemaServiceHandlerFromEndpoint 

func RegisterChannelSchemaServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterChannelSchemaServiceHandlerFromEndpoint is same as RegisterChannelSchemaServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterChannelSchemaServiceHandlerServer 

func RegisterChannelSchemaServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ChannelSchemaServiceServer) error

RegisterChannelSchemaServiceHandlerServer registers the http handlers for service ChannelSchemaService to "mux". UnaryRPC :call ChannelSchemaServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterChannelSchemaServiceHandlerFromEndpoint instead.

func RegisterChannelSchemaServiceServer 

func RegisterChannelSchemaServiceServer(s grpc.ServiceRegistrar, srv ChannelSchemaServiceServer)

Types

type BatchCreateChannelSchemasRequest 

type BatchCreateChannelSchemasRequest struct {
	Requests []*CreateChannelSchemaRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// The asset to which the channel schemas belong (case-insensitive).
	// If this field, and any of the child requests specify an asset, the assets must match.
	AssetName string `protobuf:"bytes,2,opt,name=asset_name,json=assetName,proto3" json:"asset_name,omitempty"`
	// The organization to which the channel schemas belong.
	// If this field, and any of the child requests specify an organization_id, the organization_ids must match.
	// This field is optional if the caller belongs to a single organization.
	OrganizationId string `protobuf:"bytes,3,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"`
	// contains filtered or unexported fields
}

The request for a call to `ChannelSchemaService_BatchCreateChannelSchemas`.

func (*BatchCreateChannelSchemasRequest) CloneMessageVT 

func (m *BatchCreateChannelSchemasRequest) CloneMessageVT() proto.Message

func (*BatchCreateChannelSchemasRequest) CloneVT 

func (m *BatchCreateChannelSchemasRequest) CloneVT() *BatchCreateChannelSchemasRequest

func (*BatchCreateChannelSchemasRequest) Descriptor deprecated 

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

Deprecated: Use BatchCreateChannelSchemasRequest.ProtoReflect.Descriptor instead.

func (*BatchCreateChannelSchemasRequest) EqualMessageVT 

func (this *BatchCreateChannelSchemasRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*BatchCreateChannelSchemasRequest) EqualVT 

func (this *BatchCreateChannelSchemasRequest) EqualVT(that *BatchCreateChannelSchemasRequest) bool

func (*BatchCreateChannelSchemasRequest) GetAssetName 

func (x *BatchCreateChannelSchemasRequest) GetAssetName() string

func (*BatchCreateChannelSchemasRequest) GetOrganizationId 

func (x *BatchCreateChannelSchemasRequest) GetOrganizationId() string

func (*BatchCreateChannelSchemasRequest) GetRequests 

func (x *BatchCreateChannelSchemasRequest) GetRequests() []*CreateChannelSchemaRequest

func (*BatchCreateChannelSchemasRequest) MarshalToSizedBufferVT 

func (m *BatchCreateChannelSchemasRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*BatchCreateChannelSchemasRequest) MarshalToSizedBufferVTStrict 

func (m *BatchCreateChannelSchemasRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*BatchCreateChannelSchemasRequest) MarshalToVT 

func (m *BatchCreateChannelSchemasRequest) MarshalToVT(dAtA []byte) (int, error)

func (*BatchCreateChannelSchemasRequest) MarshalToVTStrict 

func (m *BatchCreateChannelSchemasRequest) MarshalToVTStrict(dAtA []byte) (int, error)

func (*BatchCreateChannelSchemasRequest) MarshalVT 

func (m *BatchCreateChannelSchemasRequest) MarshalVT() (dAtA []byte, err error)

func (*BatchCreateChannelSchemasRequest) MarshalVTStrict 

func (m *BatchCreateChannelSchemasRequest) MarshalVTStrict() (dAtA []byte, err error)

func (*BatchCreateChannelSchemasRequest) ProtoMessage 

func (*BatchCreateChannelSchemasRequest) ProtoMessage()

func (*BatchCreateChannelSchemasRequest) ProtoReflect 

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

func (*BatchCreateChannelSchemasRequest) Reset 

func (x *BatchCreateChannelSchemasRequest) Reset()

func (*BatchCreateChannelSchemasRequest) SizeVT 

func (m *BatchCreateChannelSchemasRequest) SizeVT() (n int)

func (*BatchCreateChannelSchemasRequest) String 

func (x *BatchCreateChannelSchemasRequest) String() string

func (*BatchCreateChannelSchemasRequest) UnmarshalVT 

func (m *BatchCreateChannelSchemasRequest) UnmarshalVT(dAtA []byte) error

func (*BatchCreateChannelSchemasRequest) UnmarshalVTUnsafe 

func (m *BatchCreateChannelSchemasRequest) UnmarshalVTUnsafe(dAtA []byte) error

type BatchCreateChannelSchemasResponse 

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

The response of a call to `ChannelSchemaService_BatchCreateChannelSchemas`.

func (*BatchCreateChannelSchemasResponse) CloneMessageVT 

func (m *BatchCreateChannelSchemasResponse) CloneMessageVT() proto.Message

func (*BatchCreateChannelSchemasResponse) CloneVT 

func (m *BatchCreateChannelSchemasResponse) CloneVT() *BatchCreateChannelSchemasResponse

func (*BatchCreateChannelSchemasResponse) Descriptor deprecated 

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

Deprecated: Use BatchCreateChannelSchemasResponse.ProtoReflect.Descriptor instead.

func (*BatchCreateChannelSchemasResponse) EqualMessageVT 

func (this *BatchCreateChannelSchemasResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*BatchCreateChannelSchemasResponse) EqualVT 

func (this *BatchCreateChannelSchemasResponse) EqualVT(that *BatchCreateChannelSchemasResponse) bool

func (*BatchCreateChannelSchemasResponse) MarshalToSizedBufferVT 

func (m *BatchCreateChannelSchemasResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*BatchCreateChannelSchemasResponse) MarshalToSizedBufferVTStrict 

func (m *BatchCreateChannelSchemasResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*BatchCreateChannelSchemasResponse) MarshalToVT 

func (m *BatchCreateChannelSchemasResponse) MarshalToVT(dAtA []byte) (int, error)

func (*BatchCreateChannelSchemasResponse) MarshalToVTStrict 

func (m *BatchCreateChannelSchemasResponse) MarshalToVTStrict(dAtA []byte) (int, error)

func (*BatchCreateChannelSchemasResponse) MarshalVT 

func (m *BatchCreateChannelSchemasResponse) MarshalVT() (dAtA []byte, err error)

func (*BatchCreateChannelSchemasResponse) MarshalVTStrict 

func (m *BatchCreateChannelSchemasResponse) MarshalVTStrict() (dAtA []byte, err error)

func (*BatchCreateChannelSchemasResponse) ProtoMessage 

func (*BatchCreateChannelSchemasResponse) ProtoMessage()

func (*BatchCreateChannelSchemasResponse) ProtoReflect 

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

func (*BatchCreateChannelSchemasResponse) Reset 

func (x *BatchCreateChannelSchemasResponse) Reset()

func (*BatchCreateChannelSchemasResponse) SizeVT 

func (m *BatchCreateChannelSchemasResponse) SizeVT() (n int)

func (*BatchCreateChannelSchemasResponse) String 

func (x *BatchCreateChannelSchemasResponse) String() string

func (*BatchCreateChannelSchemasResponse) UnmarshalVT 

func (m *BatchCreateChannelSchemasResponse) UnmarshalVT(dAtA []byte) error

func (*BatchCreateChannelSchemasResponse) UnmarshalVTUnsafe 

func (m *BatchCreateChannelSchemasResponse) UnmarshalVTUnsafe(dAtA []byte) error

type ChannelSchemaServiceClient 

type ChannelSchemaServiceClient interface {
	// Create a channel schema
	CreateChannelSchema(ctx context.Context, in *CreateChannelSchemaRequest, opts ...grpc.CallOption) (*CreateChannelSchemaResponse, error)
	// Create a batch of channel schemas
	BatchCreateChannelSchemas(ctx context.Context, in *BatchCreateChannelSchemasRequest, opts ...grpc.CallOption) (*BatchCreateChannelSchemasResponse, error)
}

ChannelSchemaServiceClient is the client API for ChannelSchemaService 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 NewChannelSchemaServiceClient 

func NewChannelSchemaServiceClient(cc grpc.ClientConnInterface) ChannelSchemaServiceClient

type ChannelSchemaServiceServer 

type ChannelSchemaServiceServer interface {
	// Create a channel schema
	CreateChannelSchema(context.Context, *CreateChannelSchemaRequest) (*CreateChannelSchemaResponse, error)
	// Create a batch of channel schemas
	BatchCreateChannelSchemas(context.Context, *BatchCreateChannelSchemasRequest) (*BatchCreateChannelSchemasResponse, error)
	// contains filtered or unexported methods
}

ChannelSchemaServiceServer is the server API for ChannelSchemaService service. All implementations must embed UnimplementedChannelSchemaServiceServer for forward compatibility

type CreateChannelSchemaRequest 

type CreateChannelSchemaRequest struct {

	// The name of the component (case-insensitive).
	Component string `protobuf:"bytes,1,opt,name=component,proto3" json:"component,omitempty"`
	// The name of the channel (case-insensitive).
	Channel          string                       `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel,omitempty"`
	Unit             string                       `protobuf:"bytes,3,opt,name=unit,proto3" json:"unit,omitempty"`
	DataType         v1.ChannelDataType           `` /* 127-byte string literal not displayed */
	EnumTypes        []*v1.ChannelEnumType        `protobuf:"bytes,5,rep,name=enum_types,json=enumTypes,proto3" json:"enum_types,omitempty"`
	BitFieldElements []*v1.ChannelBitFieldElement `protobuf:"bytes,6,rep,name=bit_field_elements,json=bitFieldElements,proto3" json:"bit_field_elements,omitempty"`
	// The name of the asset (case-insensitive).
	AssetName string `protobuf:"bytes,7,opt,name=asset_name,json=assetName,proto3" json:"asset_name,omitempty"`
	// This field is optional if the caller belongs to a single organization.
	OrganizationId string `protobuf:"bytes,8,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"`
	// contains filtered or unexported fields
}

The request for a call to `ChannelSchemaService_CreateChannelSchema`.

func (*CreateChannelSchemaRequest) CloneMessageVT 

func (m *CreateChannelSchemaRequest) CloneMessageVT() proto.Message

func (*CreateChannelSchemaRequest) CloneVT 

func (m *CreateChannelSchemaRequest) CloneVT() *CreateChannelSchemaRequest

func (*CreateChannelSchemaRequest) Descriptor deprecated 

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

Deprecated: Use CreateChannelSchemaRequest.ProtoReflect.Descriptor instead.

func (*CreateChannelSchemaRequest) EqualMessageVT 

func (this *CreateChannelSchemaRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*CreateChannelSchemaRequest) EqualVT 

func (this *CreateChannelSchemaRequest) EqualVT(that *CreateChannelSchemaRequest) bool

func (*CreateChannelSchemaRequest) GetAssetName 

func (x *CreateChannelSchemaRequest) GetAssetName() string

func (*CreateChannelSchemaRequest) GetBitFieldElements 

func (x *CreateChannelSchemaRequest) GetBitFieldElements() []*v1.ChannelBitFieldElement

func (*CreateChannelSchemaRequest) GetChannel 

func (x *CreateChannelSchemaRequest) GetChannel() string

func (*CreateChannelSchemaRequest) GetComponent 

func (x *CreateChannelSchemaRequest) GetComponent() string

func (*CreateChannelSchemaRequest) GetDataType 

func (x *CreateChannelSchemaRequest) GetDataType() v1.ChannelDataType

func (*CreateChannelSchemaRequest) GetEnumTypes 

func (x *CreateChannelSchemaRequest) GetEnumTypes() []*v1.ChannelEnumType

func (*CreateChannelSchemaRequest) GetOrganizationId 

func (x *CreateChannelSchemaRequest) GetOrganizationId() string

func (*CreateChannelSchemaRequest) GetUnit 

func (x *CreateChannelSchemaRequest) GetUnit() string

func (*CreateChannelSchemaRequest) MarshalToSizedBufferVT 

func (m *CreateChannelSchemaRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CreateChannelSchemaRequest) MarshalToSizedBufferVTStrict 

func (m *CreateChannelSchemaRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*CreateChannelSchemaRequest) MarshalToVT 

func (m *CreateChannelSchemaRequest) MarshalToVT(dAtA []byte) (int, error)

func (*CreateChannelSchemaRequest) MarshalToVTStrict 

func (m *CreateChannelSchemaRequest) MarshalToVTStrict(dAtA []byte) (int, error)

func (*CreateChannelSchemaRequest) MarshalVT 

func (m *CreateChannelSchemaRequest) MarshalVT() (dAtA []byte, err error)

func (*CreateChannelSchemaRequest) MarshalVTStrict 

func (m *CreateChannelSchemaRequest) MarshalVTStrict() (dAtA []byte, err error)

func (*CreateChannelSchemaRequest) ProtoMessage 

func (*CreateChannelSchemaRequest) ProtoMessage()

func (*CreateChannelSchemaRequest) ProtoReflect 

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

func (*CreateChannelSchemaRequest) Reset 

func (x *CreateChannelSchemaRequest) Reset()

func (*CreateChannelSchemaRequest) SizeVT 

func (m *CreateChannelSchemaRequest) SizeVT() (n int)

func (*CreateChannelSchemaRequest) String 

func (x *CreateChannelSchemaRequest) String() string

func (*CreateChannelSchemaRequest) UnmarshalVT 

func (m *CreateChannelSchemaRequest) UnmarshalVT(dAtA []byte) error

func (*CreateChannelSchemaRequest) UnmarshalVTUnsafe 

func (m *CreateChannelSchemaRequest) UnmarshalVTUnsafe(dAtA []byte) error

type CreateChannelSchemaResponse 

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

The response of a call to `ChannelSchemaService_CreateChannelSchema`.

func (*CreateChannelSchemaResponse) CloneMessageVT 

func (m *CreateChannelSchemaResponse) CloneMessageVT() proto.Message

func (*CreateChannelSchemaResponse) CloneVT 

func (m *CreateChannelSchemaResponse) CloneVT() *CreateChannelSchemaResponse

func (*CreateChannelSchemaResponse) Descriptor deprecated 

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

Deprecated: Use CreateChannelSchemaResponse.ProtoReflect.Descriptor instead.

func (*CreateChannelSchemaResponse) EqualMessageVT 

func (this *CreateChannelSchemaResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*CreateChannelSchemaResponse) EqualVT 

func (this *CreateChannelSchemaResponse) EqualVT(that *CreateChannelSchemaResponse) bool

func (*CreateChannelSchemaResponse) MarshalToSizedBufferVT 

func (m *CreateChannelSchemaResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CreateChannelSchemaResponse) MarshalToSizedBufferVTStrict 

func (m *CreateChannelSchemaResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*CreateChannelSchemaResponse) MarshalToVT 

func (m *CreateChannelSchemaResponse) MarshalToVT(dAtA []byte) (int, error)

func (*CreateChannelSchemaResponse) MarshalToVTStrict 

func (m *CreateChannelSchemaResponse) MarshalToVTStrict(dAtA []byte) (int, error)

func (*CreateChannelSchemaResponse) MarshalVT 

func (m *CreateChannelSchemaResponse) MarshalVT() (dAtA []byte, err error)

func (*CreateChannelSchemaResponse) MarshalVTStrict 

func (m *CreateChannelSchemaResponse) MarshalVTStrict() (dAtA []byte, err error)

func (*CreateChannelSchemaResponse) ProtoMessage 

func (*CreateChannelSchemaResponse) ProtoMessage()

func (*CreateChannelSchemaResponse) ProtoReflect 

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

func (*CreateChannelSchemaResponse) Reset 

func (x *CreateChannelSchemaResponse) Reset()

func (*CreateChannelSchemaResponse) SizeVT 

func (m *CreateChannelSchemaResponse) SizeVT() (n int)

func (*CreateChannelSchemaResponse) String 

func (x *CreateChannelSchemaResponse) String() string

func (*CreateChannelSchemaResponse) UnmarshalVT 

func (m *CreateChannelSchemaResponse) UnmarshalVT(dAtA []byte) error

func (*CreateChannelSchemaResponse) UnmarshalVTUnsafe 

func (m *CreateChannelSchemaResponse) UnmarshalVTUnsafe(dAtA []byte) error

type UnimplementedChannelSchemaServiceServer 

type UnimplementedChannelSchemaServiceServer struct {
}

UnimplementedChannelSchemaServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedChannelSchemaServiceServer) BatchCreateChannelSchemas 

func (UnimplementedChannelSchemaServiceServer) BatchCreateChannelSchemas(context.Context, *BatchCreateChannelSchemasRequest) (*BatchCreateChannelSchemasResponse, error)

func (UnimplementedChannelSchemaServiceServer) CreateChannelSchema 

func (UnimplementedChannelSchemaServiceServer) CreateChannelSchema(context.Context, *CreateChannelSchemaRequest) (*CreateChannelSchemaResponse, error)

type UnsafeChannelSchemaServiceServer 

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

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

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.