| OLD | NEW |
| 1 // Code generated by protoc-gen-go. | 1 // Code generated by protoc-gen-go. |
| 2 // source: service.proto | 2 // source: service.proto |
| 3 // DO NOT EDIT! | 3 // DO NOT EDIT! |
| 4 | 4 |
| 5 /* | 5 /* |
| 6 Package services is a generated protocol buffer package. | 6 Package services is a generated protocol buffer package. |
| 7 | 7 |
| 8 It is generated from these files: | 8 It is generated from these files: |
| 9 service.proto | 9 service.proto |
| 10 state.proto | 10 state.proto |
| (...skipping 98 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 109 proto.RegisterType((*RegisterStreamRequest)(nil), "services.RegisterStre
amRequest") | 109 proto.RegisterType((*RegisterStreamRequest)(nil), "services.RegisterStre
amRequest") |
| 110 proto.RegisterType((*TerminateStreamRequest)(nil), "services.TerminateSt
reamRequest") | 110 proto.RegisterType((*TerminateStreamRequest)(nil), "services.TerminateSt
reamRequest") |
| 111 } | 111 } |
| 112 | 112 |
| 113 // Reference imports to suppress errors if they are not otherwise used. | 113 // Reference imports to suppress errors if they are not otherwise used. |
| 114 var _ context.Context | 114 var _ context.Context |
| 115 var _ grpc.ClientConn | 115 var _ grpc.ClientConn |
| 116 | 116 |
| 117 // Client API for Services service | 117 // Client API for Services service |
| 118 | 118 |
| 119 type ServicesClient interface { | 119 type ServicesClient interface { // GetConfig allows a service to retrieve the cu
rrent service configuration |
| 120 » // GetConfig allows a service to retrieve the current service configurat
ion | |
| 121 // parameters. | 120 // parameters. |
| 122 GetConfig(ctx context.Context, in *Void, opts ...grpc.CallOption) (*GetC
onfigResponse, error) | 121 GetConfig(ctx context.Context, in *Void, opts ...grpc.CallOption) (*GetC
onfigResponse, error) |
| 123 // RegisterStream is an idempotent stream state register operation. | 122 // RegisterStream is an idempotent stream state register operation. |
| 124 RegisterStream(ctx context.Context, in *RegisterStreamRequest, opts ...g
rpc.CallOption) (*LogStreamState, error) | 123 RegisterStream(ctx context.Context, in *RegisterStreamRequest, opts ...g
rpc.CallOption) (*LogStreamState, error) |
| 125 // TerminateStream is an idempotent operation to update the stream's ter
minal | 124 // TerminateStream is an idempotent operation to update the stream's ter
minal |
| 126 // index. | 125 // index. |
| 127 TerminateStream(ctx context.Context, in *TerminateStreamRequest, opts ..
.grpc.CallOption) (*Void, error) | 126 TerminateStream(ctx context.Context, in *TerminateStreamRequest, opts ..
.grpc.CallOption) (*Void, error) |
| 128 } | 127 } |
| 129 type servicesPRPCClient struct { | 128 type servicesPRPCClient struct { |
| 130 client *prpccommon.Client | 129 client *prpccommon.Client |
| (...skipping 156 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 287 0xc4, 0x26, 0x30, 0x36, 0x13, 0x86, 0x7b, 0x94, 0x4a, 0x50, 0x56, 0xab,
0xb1, 0x39, 0x58, 0x31, | 286 0xc4, 0x26, 0x30, 0x36, 0x13, 0x86, 0x7b, 0x94, 0x4a, 0x50, 0x56, 0xab,
0xb1, 0x39, 0x58, 0x31, |
| 288 0xaa, 0xc8, 0xb1, 0xca, 0x6a, 0xb8, 0x70, 0x7d, 0xe3, 0xc7, 0x7f, 0x24,
0x5e, 0x6b, 0xdf, 0x95, | 287 0xaa, 0xc8, 0xb1, 0xca, 0x6a, 0xb8, 0x70, 0x7d, 0xe3, 0xc7, 0x7f, 0x24,
0x5e, 0x6b, 0xdf, 0x95, |
| 289 0x77, 0x52, 0xe4, 0x9a, 0xa4, 0xf7, 0x04, 0xd3, 0x67, 0x94, 0xa9, 0xc8,
0xca, 0xa4, 0xfe, 0xd2, | 288 0x77, 0x52, 0xe4, 0x9a, 0xa4, 0xf7, 0x04, 0xd3, 0x67, 0x94, 0xa9, 0xc8,
0xca, 0xa4, 0xfe, 0xd2, |
| 290 0x78, 0x0a, 0xb6, 0xae, 0xdf, 0x25, 0xa1, 0xc8, 0x62, 0xfc, 0x30, 0x9d,
0xbb, 0x8b, 0xcf, 0x0e, | 289 0x78, 0x0a, 0xb6, 0xae, 0xdf, 0x25, 0xa1, 0xc8, 0x62, 0xfc, 0x30, 0x9d,
0xbb, 0x8b, 0xcf, 0x0e, |
| 291 0xf4, 0xd7, 0xcd, 0x02, 0xd8, 0x0d, 0x0c, 0x0e, 0x71, 0x31, 0xdb, 0xff,
0x5e, 0x8c, 0x5f, 0x65, | 290 0xf4, 0xd7, 0xcd, 0x02, 0xd8, 0x0d, 0x0c, 0x0e, 0x71, 0x31, 0xdb, 0xff,
0x5e, 0x8c, 0x5f, 0x65, |
| 292 0xe9, 0x5e, 0xb4, 0xf5, 0xef, 0x4c, 0x1f, 0xc0, 0xfe, 0x19, 0x07, 0xbb,
0x6c, 0xe9, 0x27, 0x83, | 291 0xe9, 0x5e, 0xb4, 0xf5, 0xef, 0x4c, 0x1f, 0xc0, 0xfe, 0x19, 0x07, 0xbb,
0x6c, 0xe9, 0x27, 0x83, |
| 293 0x72, 0x9d, 0x96, 0x70, 0x30, 0xba, 0xae, 0x7e, 0x00, 0xb6, 0x84, 0xff,
0x47, 0x1e, 0xd9, 0xac, | 292 0x72, 0x9d, 0x96, 0x70, 0x30, 0xba, 0xae, 0x7e, 0x00, 0xb6, 0x84, 0xff,
0x47, 0x1e, 0xd9, 0xac, |
| 294 0x25, 0x9f, 0xb6, 0xef, 0x1e, 0x8d, 0xbb, 0xed, 0x99, 0x9c, 0xaf, 0xbf,
0x02, 0x00, 0x00, 0xff, | 293 0x25, 0x9f, 0xb6, 0xef, 0x1e, 0x8d, 0xbb, 0xed, 0x99, 0x9c, 0xaf, 0xbf,
0x02, 0x00, 0x00, 0xff, |
| 295 0xff, 0xab, 0x0d, 0x40, 0x9f, 0x6e, 0x02, 0x00, 0x00, | 294 0xff, 0xab, 0x0d, 0x40, 0x9f, 0x6e, 0x02, 0x00, 0x00, |
| 296 } | 295 } |
| OLD | NEW |