source

package
v0.0.0-...-a019193 Latest Latest
Warning

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

 Go to latest Published: Feb 23, 2025 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Status_name = map[int32]string{
		0: "STATUS_ACTIVE",
		1: "STATUS_NOT_ACTIVE",
	}
	Status_value = map[string]int32{
		"STATUS_ACTIVE":     0,
		"STATUS_NOT_ACTIVE": 1,
	}
)

Enum value maps for Status.

View Source 
var File_source_source_proto protoreflect.FileDescriptor
View Source 
var IsWriteKeyValid_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "source.IsWriteKeyValid",
	HandlerType: (*IsWriteKeyValidServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "IsWriteKeyValid",
			Handler:    _IsWriteKeyValid_IsWriteKeyValid_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "source/source.proto",
}

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

Functions

func RegisterIsWriteKeyValidServer 

func RegisterIsWriteKeyValidServer(s grpc.ServiceRegistrar, srv IsWriteKeyValidServer)

Types

type IsWriteKeyValidClient 

type IsWriteKeyValidClient interface {
	IsWriteKeyValid(ctx context.Context, in *ValidateWriteKeyReq, opts ...grpc.CallOption) (*ValidateWriteKeyResp, error)
}

IsWriteKeyValidClient is the client API for IsWriteKeyValid 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 NewIsWriteKeyValidClient 

func NewIsWriteKeyValidClient(cc grpc.ClientConnInterface) IsWriteKeyValidClient

type IsWriteKeyValidServer 

type IsWriteKeyValidServer interface {
	IsWriteKeyValid(context.Context, *ValidateWriteKeyReq) (*ValidateWriteKeyResp, error)
	// contains filtered or unexported methods
}

IsWriteKeyValidServer is the server API for IsWriteKeyValid service. All implementations must embed UnimplementedIsWriteKeyValidServer for forward compatibility

type NewEvent 

type NewEvent struct {
	Id         string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type       string               `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Name       string               `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Properties map[string]string    `` /* 161-byte string literal not displayed */
	SendAt     *timestamp.Timestamp `protobuf:"bytes,5,opt,name=send_at,json=sendAt,proto3" json:"send_at,omitempty"`
	ReceivedAt *timestamp.Timestamp `protobuf:"bytes,6,opt,name=received_at,json=receivedAt,proto3" json:"received_at,omitempty"`
	Timestamp  *timestamp.Timestamp `protobuf:"bytes,7,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Event      string               `protobuf:"bytes,8,opt,name=event,proto3" json:"event,omitempty"`
	WriteKey   string               `protobuf:"bytes,9,opt,name=write_key,json=writeKey,proto3" json:"write_key,omitempty"`
	CreatedAt  *timestamp.Timestamp `protobuf:"bytes,10,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt  *timestamp.Timestamp `protobuf:"bytes,11,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*NewEvent) Descriptor deprecated 

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

Deprecated: Use NewEvent.ProtoReflect.Descriptor instead.

func (*NewEvent) GetCreatedAt 

func (x *NewEvent) GetCreatedAt() *timestamp.Timestamp

func (*NewEvent) GetEvent 

func (x *NewEvent) GetEvent() string

func (*NewEvent) GetId 

func (x *NewEvent) GetId() string

func (*NewEvent) GetName 

func (x *NewEvent) GetName() string

func (*NewEvent) GetProperties 

func (x *NewEvent) GetProperties() map[string]string

func (*NewEvent) GetReceivedAt 

func (x *NewEvent) GetReceivedAt() *timestamp.Timestamp

func (*NewEvent) GetSendAt 

func (x *NewEvent) GetSendAt() *timestamp.Timestamp

func (*NewEvent) GetTimestamp 

func (x *NewEvent) GetTimestamp() *timestamp.Timestamp

func (*NewEvent) GetType 

func (x *NewEvent) GetType() string

func (*NewEvent) GetUpdatedAt 

func (x *NewEvent) GetUpdatedAt() *timestamp.Timestamp

func (*NewEvent) GetWriteKey 

func (x *NewEvent) GetWriteKey() string

func (*NewEvent) ProtoMessage 

func (*NewEvent) ProtoMessage()

func (*NewEvent) ProtoReflect 

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

func (*NewEvent) Reset 

func (x *NewEvent) Reset()

func (*NewEvent) String 

func (x *NewEvent) String() string

type NewSourceEvent 

type NewSourceEvent struct {
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	OwnerId   string `protobuf:"bytes,2,opt,name=owner_id,json=ownerId,proto3" json:"owner_id,omitempty"`
	WriteKey  string `protobuf:"bytes,3,opt,name=write_key,json=writeKey,proto3" json:"write_key,omitempty"`
	// contains filtered or unexported fields
}

func (*NewSourceEvent) Descriptor deprecated 

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

Deprecated: Use NewSourceEvent.ProtoReflect.Descriptor instead.

func (*NewSourceEvent) GetOwnerId 

func (x *NewSourceEvent) GetOwnerId() string

func (*NewSourceEvent) GetProjectId 

func (x *NewSourceEvent) GetProjectId() string

func (*NewSourceEvent) GetWriteKey 

func (x *NewSourceEvent) GetWriteKey() string

func (*NewSourceEvent) ProtoMessage 

func (*NewSourceEvent) ProtoMessage()

func (*NewSourceEvent) ProtoReflect 

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

func (*NewSourceEvent) Reset 

func (x *NewSourceEvent) Reset()

func (*NewSourceEvent) String 

func (x *NewSourceEvent) String() string

type Source 

type Source struct {
	Id          string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	WriteKey    string               `protobuf:"bytes,2,opt,name=write_key,json=writeKey,proto3" json:"write_key,omitempty"`
	Name        string               `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Description string               `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	ProjectId   string               `protobuf:"bytes,5,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	OwnerId     string               `protobuf:"bytes,6,opt,name=owner_id,json=ownerId,proto3" json:"owner_id,omitempty"`
	Status      Status               `protobuf:"varint,7,opt,name=status,proto3,enum=source.Status" json:"status,omitempty"`
	Metadata    *SourceMetadata      `protobuf:"bytes,8,opt,name=metadata,proto3" json:"metadata,omitempty"`
	CreatedAt   *timestamp.Timestamp `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt   *timestamp.Timestamp `protobuf:"bytes,10,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	DeletedAt   *timestamp.Timestamp `protobuf:"bytes,11,opt,name=deleted_at,json=deletedAt,proto3" json:"deleted_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Source) Descriptor deprecated 

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

Deprecated: Use Source.ProtoReflect.Descriptor instead.

func (*Source) GetCreatedAt 

func (x *Source) GetCreatedAt() *timestamp.Timestamp

func (*Source) GetDeletedAt 

func (x *Source) GetDeletedAt() *timestamp.Timestamp

func (*Source) GetDescription 

func (x *Source) GetDescription() string

func (*Source) GetId 

func (x *Source) GetId() string

func (*Source) GetMetadata 

func (x *Source) GetMetadata() *SourceMetadata

func (*Source) GetName 

func (x *Source) GetName() string

func (*Source) GetOwnerId 

func (x *Source) GetOwnerId() string

func (*Source) GetProjectId 

func (x *Source) GetProjectId() string

func (*Source) GetStatus 

func (x *Source) GetStatus() Status

func (*Source) GetUpdatedAt 

func (x *Source) GetUpdatedAt() *timestamp.Timestamp

func (*Source) GetWriteKey 

func (x *Source) GetWriteKey() string

func (*Source) ProtoMessage 

func (*Source) ProtoMessage()

func (*Source) ProtoReflect 

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

func (*Source) Reset 

func (x *Source) Reset()

func (*Source) String 

func (x *Source) String() string

type SourceMetadata 

type SourceMetadata 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"`
	Slug     string `protobuf:"bytes,3,opt,name=slug,proto3" json:"slug,omitempty"`
	Category string `protobuf:"bytes,4,opt,name=category,proto3" json:"category,omitempty"`
	// contains filtered or unexported fields
}

func (*SourceMetadata) Descriptor deprecated 

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

Deprecated: Use SourceMetadata.ProtoReflect.Descriptor instead.

func (*SourceMetadata) GetCategory 

func (x *SourceMetadata) GetCategory() string

func (*SourceMetadata) GetId 

func (x *SourceMetadata) GetId() string

func (*SourceMetadata) GetName 

func (x *SourceMetadata) GetName() string

func (*SourceMetadata) GetSlug 

func (x *SourceMetadata) GetSlug() string

func (*SourceMetadata) ProtoMessage 

func (*SourceMetadata) ProtoMessage()

func (*SourceMetadata) ProtoReflect 

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

func (*SourceMetadata) Reset 

func (x *SourceMetadata) Reset()

func (*SourceMetadata) String 

func (x *SourceMetadata) String() string

type Status 

type Status int32
const (
	Status_STATUS_ACTIVE     Status = 0
	Status_STATUS_NOT_ACTIVE Status = 1
)

func (Status) Descriptor 

func (Status) Descriptor() protoreflect.EnumDescriptor

func (Status) Enum 

func (x Status) Enum() *Status

func (Status) EnumDescriptor deprecated 

func (Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use Status.Descriptor instead.

func (Status) Number 

func (x Status) Number() protoreflect.EnumNumber

func (Status) String 

func (x Status) String() string

func (Status) Type 

func (Status) Type() protoreflect.EnumType

type UnimplementedIsWriteKeyValidServer 

type UnimplementedIsWriteKeyValidServer struct {
}

UnimplementedIsWriteKeyValidServer must be embedded to have forward compatible implementations.

func (UnimplementedIsWriteKeyValidServer) IsWriteKeyValid 

func (UnimplementedIsWriteKeyValidServer) IsWriteKeyValid(context.Context, *ValidateWriteKeyReq) (*ValidateWriteKeyResp, error)

type UnsafeIsWriteKeyValidServer 

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

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

type ValidateWriteKeyReq 

type ValidateWriteKeyReq struct {
	WriteKey string `protobuf:"bytes,1,opt,name=write_key,json=writeKey,proto3" json:"write_key,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateWriteKeyReq) Descriptor deprecated 

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

Deprecated: Use ValidateWriteKeyReq.ProtoReflect.Descriptor instead.

func (*ValidateWriteKeyReq) GetWriteKey 

func (x *ValidateWriteKeyReq) GetWriteKey() string

func (*ValidateWriteKeyReq) ProtoMessage 

func (*ValidateWriteKeyReq) ProtoMessage()

func (*ValidateWriteKeyReq) ProtoReflect 

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

func (*ValidateWriteKeyReq) Reset 

func (x *ValidateWriteKeyReq) Reset()

func (*ValidateWriteKeyReq) String 

func (x *ValidateWriteKeyReq) String() string

type ValidateWriteKeyResp 

type ValidateWriteKeyResp struct {
	IsValid   bool   `protobuf:"varint,1,opt,name=is_valid,json=isValid,proto3" json:"is_valid,omitempty"`
	ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	OwnerId   string `protobuf:"bytes,3,opt,name=owner_id,json=ownerId,proto3" json:"owner_id,omitempty"`
	WriteKey  string `protobuf:"bytes,4,opt,name=write_key,json=writeKey,proto3" json:"write_key,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateWriteKeyResp) Descriptor deprecated 

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

Deprecated: Use ValidateWriteKeyResp.ProtoReflect.Descriptor instead.

func (*ValidateWriteKeyResp) GetIsValid 

func (x *ValidateWriteKeyResp) GetIsValid() bool

func (*ValidateWriteKeyResp) GetOwnerId 

func (x *ValidateWriteKeyResp) GetOwnerId() string

func (*ValidateWriteKeyResp) GetProjectId 

func (x *ValidateWriteKeyResp) GetProjectId() string

func (*ValidateWriteKeyResp) GetWriteKey 

func (x *ValidateWriteKeyResp) GetWriteKey() string

func (*ValidateWriteKeyResp) ProtoMessage 

func (*ValidateWriteKeyResp) ProtoMessage()

func (*ValidateWriteKeyResp) ProtoReflect 

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

func (*ValidateWriteKeyResp) Reset 

func (x *ValidateWriteKeyResp) Reset()

func (*ValidateWriteKeyResp) String 

func (x *ValidateWriteKeyResp) 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.